package com.springboot.study.producer;

import com.springboot.study.config.FanoutConfig;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
/**
 * 发布者（生产者） - 广播模式
 */
@RestController
@RequestMapping("/fanout")
public class FanoutProducer {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    /**
     * 广播消息
     * @param message 要发送的消息
     */
    @GetMapping("/send")
    public String broadcast(@RequestParam String message) {
        // 发送到 Fanout 交换机，不需要 RoutingKey
        rabbitTemplate.convertAndSend(FanoutConfig.FANOUT_EXCHANGE, "", message);
        return "广播消息发送成功：" + message;
    }
}
